package msgqueue

type Queue interface {
	Push(msg interface{}) error
	Pop() (interface{}, error)
	Count() int
}

func CreateQueue(t string) (q Queue) {
	switch t {
	default:
		q = new(MsgQueue)
		break
	}
	return
}
